require 'rubygems'
require 'java'
require 'hazelcast.jar'

import com.hazelcast.core.Member
import com.hazelcast.core.Hazelcast
import com.hazelcast.core.MultiTask
import com.hazelcast.core.DistributedTask
import java.util.concurrent.ExecutorService
import java.util.concurrent.FutureTask  
import java.util.concurrent.Future  
import java.util.Set

def echo_on_the_member(input, member)
       task = DistributedTask.new
       executorService = Hazelcast.getExecutorService();
       executorService.execute(task);
       echoResult = task.get();
end